package hello

import (
	"fmt"
)

/*
通道（channel）是用来传递数据的一个数据结构。

ch <- v    // 把 v 发送到通道 ch
v := <-ch  // 从 ch 接收数据， 并把值赋给 v

ch := make(chan int) // 声明一个通道
ch := make(chan int, 100)  // 声明一个 有缓冲区的通道
*/

func sum(s []int, c chan int) {
	sum := 0
	for _, v := range s {
		sum += v
	}
	c <- sum // 把 sum 发送到通道 c
}

func ChannelTest1() {
	fmt.Println("------------ channel Test1() --------------")

	s := []int{7, 2, 8, -9, 4, 0}

	c := make(chan int)
	go sum(s[:len(s)/2], c)
	go sum(s[len(s)/2:], c)
	x, y := <-c, <-c // 从通道 c 中接收

	fmt.Println(x, y, x+y)

	fmt.Println("------------ channel Test2() --------------")
	// 这里我们定义了一个可以存储整数类型的带缓冲通道
	// 缓冲区大小为2
	ch := make(chan int, 2)

	// 因为 ch 是带缓冲的通道，我们可以同时发送两个数据
	// 而不用立刻需要去同步读取数据
	ch <- 1
	fmt.Println(<-ch)
	ch <- 2
	ch <- 3

	// 获取这两个数据
	fmt.Println(<-ch)
	fmt.Println(<-ch)

	fmt.Println("------------ channel Test3() --------------")
	//Go 遍历通道与关闭通道
	// v, ok := <-ch   如果通道接收不到数据后 ok 就为 false，这时通道就可以使用 close() 函数来关闭。
	c1 := make(chan int, 10)
	go fibonacci(cap(c1), c1)
	// range 函数遍历每个从通道接收到的数据，因为 c 在发送完 10 个
	// 数据之后就关闭了通道，所以这里我们 range 函数在接收到 10 个数据
	// 之后就结束了。如果上面的 c 通道不关闭，那么 range 函数就不
	// 会结束，从而在接收第 11 个数据的时候就阻塞了。
	for i := range c1 {
		fmt.Println(i)
	}
}

func fibonacci(n int, c chan int) {
	x, y := 0, 1
	for i := 0; i < n; i++ {
		c <- x
		x, y = y, x+y
	}
	close(c)
}
